# -*- coding:utf-8 -*-
import importlib
import os
import sys
from service.yaml_operation import getDict
from service.argparse_operation import getParameters

#识别yaml中的Task任务，调用指定模块运行。
def TaskRun(yaml_config):
    for i in yaml_config['Task']:
        for key,value in i.items():
            if key == 'name':
                print('当前正在执行任务：%s'%value)
            else:
                introduce_module = importlib.import_module('module.' + key + '.main')
                introduce_module.run(value)
        
        

def Run():
    os.chdir(sys.path[0])
    yaml_config = getDict('yaml/' + str(getParameters().config))
    
    #执行Task中的任务
    TaskRun(yaml_config)


if __name__ == '__main__':
    Run()